package pro.cherish.knowledgerabbitmqconsumer.listener;

import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
import pro.cherish.knowledgerabbitmqconsumer.config.QueueConfig;

import java.time.LocalDateTime;

/**
 * @author 创建人：lys
 * @version 版本号：V1.0
 * <p>
 * ***************************修订记录************************************
 * 2020-3-22 lys 创建该类功能。
 * **********************************************************************
 * </p>
 * @ClassName 类名：ListernA
 * @Description 功能说明：
 * <p>
 * TODO
 * </p>
 * **********************************************************************
 * @date 创建日期： 2020-3-22
 */
@Component
@Slf4j
public class ListernA {

    @RabbitListener(queues = QueueConfig.QUENE_A, containerFactory = "normalListenerContainer")
    public void listernA(String msgStr, Message message, Channel channel) {
        log.info("[消息消费时间] - [{}] - [a 监听的消息] - [{}]", LocalDateTime.now(), msgStr);
        try {
            Thread.sleep(20000);
            // 通知 MQ 消息已被成功消费,可以ACK了
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
        } catch (Exception e) {
            log.error("消息消费失败,错误日志= 【{}】", e.toString());
        }
    }
}
